package cn.gwm.flink.streaming.function.reduce;

import cn.gwm.flink.streaming.beans.estimateSoh.EstimateSohRecord;
import org.apache.flink.api.common.functions.ReduceFunction;
import org.apache.flink.api.common.functions.RichReduceFunction;

import java.math.BigDecimal;

/**
 * @author GW00283474
 */
public class EstimateSohReduceFunction implements ReduceFunction<BigDecimal> {

    @Override
    public BigDecimal reduce(BigDecimal value1, BigDecimal value2) throws Exception {
        return value1.add(value2);
    }
}
